package com.cn.gmall.activity.redis;

import com.cn.gmall.activity.cache.CacheHelper;
import org.apache.commons.lang.StringUtils;
import org.springframework.stereotype.Component;

@Component
public class ReceiverMessage {
//    创建消费对象
public void messageReceive(String message){
//-------------判断 (此时数据格式 形如  ""23:1""  )------------------
    if(!StringUtils.isEmpty(message)){
        
        //处理数据，去掉双引号
        message = message.replaceAll("\"", "");
        //切割字符串“:”
        String[] split = message.split(":");
        //判断
        if(split!=null &&split.length==2){
//   -------------加到本地缓存---每次重启服务jvm会自动清除-- 需要再次加入缓存----------
            CacheHelper.put(split[0],split[1]);

        }


    }



    System.out.println(message);


}

}
